# 编写celery客户端代码
from celery import Celery
import os


# celery 模块中尽量不要打入celery模块以外的其他模块, 可能出现位置bug
# 解决方案: 1. 把要导入的模块拉进来 2. 加入下面这句话
os.environ.setdefault("DJANGO_SETTINGS_MODULE", "meiduo_mall.settings.dev")

# 1. 创建celery客户端对象
celery_app = Celery('meiduo')

# 2. 加载celery配置信息(仓库/消息队列是谁,在哪里)
celery_app.config_from_object('celery_tasks.config')

# 3. celery 可以生产什么任务
celery_app.autodiscover_tasks(['celery_tasks.sms', 'celery_tasks.email'])
